package com.oct.ywsc.core.config;

import lombok.Data;

@Data
public class KafkaSaslConfig {

    // 标记是否开启安全认证
    private Boolean enableSecurity;
    private String securityProtocol;
    private String saslMechanism;
    private String saslJaasConfig;
    private String sslTruststoreLocation;
    private String sslTruststorePassword;
    private String sslEndpointIdentificationAlgorithm;

    public String getSslEndpointIdentificationAlgorithm() {
        return "none".equals(sslEndpointIdentificationAlgorithm) ? "" : sslEndpointIdentificationAlgorithm;
    }
}
